## 导入tushare
import tushare as ts
import time
# 设置token
ts.set_token('531f7eda35d265a43c7091a5971802aab320a80c16afb6e7164c595a')
# 初始化pro接口
pro = ts.pro_api()

# 市场代码	说明
# MSCI	MSCI指数
# CSI	中证指数
# SSE	上交所指数
# SZSE	深交所指数
# CICC	中金指数
# SW	申万指数
# OTH	其他指数
df = pro.index_basic(market='SSE', fields="ts_code,name,market,publisher,category")
print(df)
# df = pro.trade_cal(exchange='', start_date='20180901', end_date='20181001',
#                   fields='exchange,cal_date,is_open,pretrade_date', is_open='0')
# 指数日线行情
# 输入参数
# 名称	类型	必选	描述
# ts_code	str	Y	指数代码
# trade_date	str	N	交易日期 （日期格式：YYYYMMDD，下同）
# start_date	str	N	开始日期
# end_date	str	N	结束日期
# 输出参数
# 名称	类型	描述
# ts_code	str	TS指数代码
# trade_date	str	交易日
# close	float	收盘点位
# open	float	开盘点位
# high	float	最高点位
# low	float	最低点位
# pre_close	float	昨日收盘点
# change	float	涨跌点
# pct_chg	float	涨跌幅（%）
# vol	float	成交量（手）
# amount	float	成交额（千元）
curDate = time.strftime("%Y%m%d", time.localtime())# 格式化成20160320
df = pro.index_daily(ts_code='399300.SZ', start_date='20210101', end_date=curDate,
                     fields='ts_code,trade_date,close,change,pct_chg')
print(df)

# 查询当前所有正常上市交易的股票列表

data = pro.stock_basic(exchange='', list_status='L', fields='ts_code,symbol,name,area,industry,list_date')
print(data)
print(data.size)

print("###############################################################################################################")
from sqlalchemy import create_engine
import tushare as ts

df = ts.get_tick_data('600848', date='2014-12-22')
engine = create_engine('mysql://root:123456@127.0.0.1/kaifamiao?charset=utf8')

# 存入数据库
#df.to_sql('tick_data',engine)

# 追加数据到现有表
# df.to_sql('tick_data',engine,if_exists='append')